<?php
namespace app\common\services;

use app\models\QueueList;

/**
 * Class QueueListService
 * QueueList表, 作为消息队列的生产者
 * Author: yanhaoqiang
 * @package app\common\services
 */
class QueueListService extends BaseService {

    /**
     * [addQueue 将需要的业务添加进来]
     * 消息队列也可以使用redis实现,redis实现方式更通用,这里用mysql是考虑机器性能不足的问题,也简单
     * @param $queue_name
     * @param array $data
     * @return bool
     */
    public static function addQueue($queue_name, $data = []) {
        $model = new QueueList();
        $model->queue_name = $queue_name;
        $model->data = json_encode($data);
        $model->status = -1;
        $model->created_time = $model->updated_time = date("Y-m-d H:i:s");
        //在数据库中添加一条记录
        return $model->save(0);
    }

}